package cn.wisenergy.pai.monitor.collector;

import kafka.consumer.KafkaStream;
/**
 * 
 * the KafkaTimeNodeProcessor interface should be asynchronized process kafka stream
 *
 */
public interface TimeNodeProcessor extends Runnable{

	public void init(KafkaStream<byte[], byte[]> m_stream, int m_threadNumber);

}
